package com.atguigu.gmall.realtime.util;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @Author lzc
 * @Date 2022/12/14 09:16
 */
public class ThreadPoolUtil {
    // 获取一个线程池, 然后把要执行的任务交给线程池执行
    public static ThreadPoolExecutor getThreadPool(){
        return new ThreadPoolExecutor(
            300,  // 核心线程数
            500,  // 最大线程数
            60,  // 最大线程数-核心线程数 这些线程空闲的时间
            TimeUnit.SECONDS,
            new LinkedBlockingQueue<>()
        );
    }
}
